package org.zhb.querysql.websocket.reverse;

import java.io.IOException;

import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @Title: ReverseWebSocketEndpoint.java
 * @Package org.zhb.querysql.websocket.reverse
 * @Description: 反转消息处理
 * @author zhb
 * @date 2016年5月12日 上午10:00:34
 * @version V1.0
 */
// 通过注解的方式发布ws服务--
@ServerEndpoint("/reverse")
public class ReverseWebSocketEndpoint {
	private static Logger logger = LoggerFactory.getLogger(ReverseWebSocketEndpoint.class);

	/**
	 * @Title: handleMessage
	 * @Description: 自定义消息出处理类
	 * @param session
	 * @param message
	 * @throws IOException
	 * @return: void
	 * @author: zhb
	 * @throws 2016年5月12日上午10:51:06
	 */
	@OnMessage
	public void handleMessage(Session session, String message) throws IOException {
		logger.info(message);
		session.getBasicRemote().sendText("Reversed: " + new StringBuilder(message).reverse());
	}
}
